package com.wande.dataplatform.etl.node;

import lombok.Data;

/**
 * ETL统计信息
 *
 * @author dataplatform
 */
@Data
public class EtlStatistics {

    /**
     * 源数据行数
     */
    private long sourceRows = 0;

    /**
     * 目标数据行数
     */
    private long targetRows = 0;

    /**
     * 成功行数
     */
    private long successRows = 0;

    /**
     * 失败行数
     */
    private long failedRows = 0;

    /**
     * 增加源数据行数
     */
    public void addSourceRows(long rows) {
        this.sourceRows += rows;
    }

    /**
     * 增加目标数据行数
     */
    public void addTargetRows(long rows) {
        this.targetRows += rows;
    }

    /**
     * 增加成功行数
     */
    public void addSuccessRows(long rows) {
        this.successRows += rows;
    }

    /**
     * 增加失败行数
     */
    public void addFailedRows(long rows) {
        this.failedRows += rows;
    }
}
